const Subscription = require('egg').Subscription;
class UpdateCache extends Subscription {
    // 通过 schedule 属性来设置定时任务的执行间隔等配置
    static get schedule() {
        return {
            interval: '5s', // 1 分钟间隔
            type: 'all', // 指定所有的 worker 都需要执行
        };
    }

    // subscribe 是真正定时任务执行时被运行的函数
    async subscribe() {
        const {ctx, app} = this;
        const data = await ctx.service.spider.spiderData();
        const cache = app.redis.get('catch_weather');
        if (cache === data) {
            console.log(cache)
        } else {
            app.redis.set('catch_weather', data);
            console.log(data)
            app.cache = data;

        }

    }
}

module.exports = UpdateCache;